/*
package com.ruoyi.web.consumer;


import com.ruoyi.datastatistics.service.ISiLiancallBackService;
import com.ruoyi.datastatistics.service.impl.SiLiancallBackServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;

@Component
@Repository
@Slf4j
@RocketMQMessageListener(topic = "siliandtunettyTopic", consumerGroup = "silian")
public class SiLianConsumer implements RocketMQListener<String> {

    @Autowired
    private ISiLiancallBackService siLiancallBackService;

    @Override
    public void onMessage(String message) {
        System.out.println(message);
        //log.info("----------------------消费");
        try{
            siLiancallBackService.callBackSubscribe(message);
            //message(message);
        }catch (Exception e){
            log.error("----------------------GuoXinDTUConsumer消费异常"+e.getMessage());
        }
    }
}
*/
